package com.calabar.phm.etl.operator.api;

import org.apache.spark.sql.Dataset;
import org.apache.spark.sql.Row;
import org.apache.spark.sql.SparkSession;

/**
 * @Author zmc <mingcheng.zhang@cdcalabar.com>
 * @Date 17-5-18 下午3:15
 * @Version v2.0
 * @Des 输出算子基类
 */
public interface OutputTransformer {


    /**
     * 存储传入的DataFrame
     *
     * @param session spark上下文
     * @param df      需要存储的DataFrame
     * @throws Exception
     */
    void transform(SparkSession session, Dataset<Row> df) throws Exception;

}
